package com.zc.study

import org.apache.flink.api.scala._
import org.apache.flink.core.fs.FileSystem.WriteMode

object DataSetSink {

  def main(args: Array[String]): Unit = {
    val env = ExecutionEnvironment.createLocalEnvironment();
    val dataSet = env.fromCollection(1 to 11)
    dataSet.writeAsText("Z:\\gitee\\study_imooc\\test-data\\flink\\sink-scala\\", WriteMode.OVERWRITE).setParallelism(3)
    env.execute("DataSetSink")
  }
}
